package cc.example;

import reactor.core.publisher.Flux;

public class 请求重塑buffer {
    public static void main(String[] args) {
        Flux.range(1,10)
                .buffer(3) //  订阅请求一次可以可以拿3个元素
                .log()
                .subscribe();
    }
}
